Node / rns-mirrors / Reticulum-Go.git / files / pkg / controlapi / lifecycle.go

Displaying Raw • Download

// SPDX-License-Identifier: Apache-2.0

// Copyright (c) 2024-2026 Quad4.io

package controlapi

import (

"encoding/hex"

"io"

"net/http"

)

type refreshPathsRequest struct {

Destinations []string \\`json:"destinations"\\`

}

func (s *Server) handleLifecycleResume(w http.ResponseWriter, r *http.Request) {

if s.lifecycle == nil {

writeError(w, http.StatusNotImplemented, "lifecycle not configured")

return

}

if err := s.lifecycle.OnNetworkAvailable(); err != nil {

writeError(w, http.StatusInternalServerError, err.Error())

return

}

writeJSON(w, http.StatusOK, map[string]string{"status": "resumed"})

}

func (s *Server) handleLifecyclePause(w http.ResponseWriter, r *http.Request) {

if s.lifecycle == nil {

writeError(w, http.StatusNotImplemented, "lifecycle not configured")

return

}

if err := s.lifecycle.OnNetworkLost(); err != nil {

writeError(w, http.StatusInternalServerError, err.Error())

return

}

writeJSON(w, http.StatusOK, map[string]string{"status": "paused"})

}

func (s *Server) handleLifecycleRefreshPaths(w http.ResponseWriter, r *http.Request) {

if s.lifecycle == nil {

writeError(w, http.StatusNotImplemented, "lifecycle not configured")

return

}

var req refreshPathsRequest

if r.Body != nil {

err := decodeJSONBody(w, r, &req)

if isBodyTooLarge(err) {

return

}

// Optional body: ignore empty or malformed JSON, but still enforce size.

if err != nil && err != io.EOF {

req = refreshPathsRequest{}

}

}

dests := make([][]byte, 0, len(req.Destinations))

for _, h := range req.Destinations {

b, err := hex.DecodeString(h)

if err != nil || len(b) != 16 {

writeError(w, http.StatusBadRequest, "invalid destination hash")

return

}

dests = append(dests, b)

}

if err := s.lifecycle.RefreshPaths(dests...); err != nil {

writeError(w, http.StatusInternalServerError, err.Error())

return

}

writeJSON(w, http.StatusOK, map[string]string{"status": "refreshed"})

}